package com.pie4cloud.pie.bus.api.consumer;

import com.pie4cloud.pie.common.core.util.R;


public interface IKfkaConsumer {

    /**
     * consume message
     *
     * @param data
     * @return
     * @throws Exception
     */
    public R consume(String data,String topic,String groupId) throws Exception;

}
